const {ChatModel}= require( '../db/model')

module.exports = function (server) {
    const io = require("socket.io")(server)
    io.on("connection",socket=>{
        socket.on("sendMsg",({from,to ,content})=>{
            console.log("服务器收到客户端发送的数据",{from,to, content})
            //生成数据库中的数据格式
            const chat_id = [from,to].sort().join('_')
            const create_time = Date.now()
            new ChatModel({from,to ,chat_id,content,create_time}).save(function (err,chat_msg) {
                //向客户端发送消息
                //这里为了方便直接向所有连接的客户端发送数据，客户端只需要识别一下是否是属于自己的数据
                io.emit("receiveMsg",chat_msg)
            })
        })
    })
}